package com.atguigu;

import com.streamxhub.streamx.flink.core.TableContext;
import com.streamxhub.streamx.flink.core.TableEnvConfig;

/**
 * @Author lzc
 * @Date 2022/4/27 16:18
 */
public class Streamx_sql {
    public static void main(String[] args) {
        TableEnvConfig config = new TableEnvConfig(args, null);
        TableContext ctx = new TableContext(config);
        
        
        ctx.sql("first");
    }
}
